---电子面单回收表：yl_elec_recycle 电子面单回收明细  （与何郑沟通）
---唯一标识一条记录是 bill_code运单号、get_time 获取面单时间
---当天更新历史数据的一个最大时间范围是：一年之内 改变字段 recycle_status 为 3-已管控
---回收面单时间！=创建时间（平台会给回收时间,就取平台的没有时用创建时间）
---清洗处理：用bill_code运单号、get_time 获取面单时间去重,15天内。回收时间作为分区字段。统一网点名称
insert overwrite table jms_dwd.dwd_elec_recycle_base_dt partition(dt)
select 
	 t.id
	,t.bill_code
	,t.trace_id
	,t.recycle_object
	,t.recycle_status
	,t.recycle_time
	,t.recycle_fail_reason
	,t.get_time
	,t.site_code
	,net1.name as site_name
	,t.mall_id
	,t.mall_name
	,t.customer_code
	,t.source_code
	,t.scan_status
	,t.remarks
	,t.create_time
	,t.update_time
	,t.customer_name
	,t.sale_code
	,t.sale_name
	,substr(t.recycle_time,1,10) as dt
from
(
select 
*,
ROW_NUMBER() over(partition by bill_code,get_time order by update_time desc) rk
from jms_ods.yl_elec_recycle
where dt>=DATE_ADD('{{ execution_date | cst_ds }}',-14) and dt<= '{{ execution_date | cst_ds }}'
) t 
left join jms_dim.dim_network_whole_massage net1 on t.site_code=net1.code
where rk=1 and 
date(t.recycle_time)>=DATE_ADD('{{ execution_date | cst_ds }}',-14) and
date(t.recycle_time)<='{{ execution_date | cst_ds }}'
    distribute by dt,1;